package com.we.flink.userlabelplatform.table;

import java.sql.Timestamp;

public class TableUserAmountRetrialAudit {
    public static final String KFKTABLE = "fdm.hhl01_user_amount_retrial_audit";
    public static final String QUERYSQL =
            "select uid, create_time, "
                    + "if(audit_time is null, TIMESTAMP '1970-01-01 08:00:00.000000', audit_time) as audit_time, "
                    + "if(audit_status is null, 0, audit_status) as audit_status, "
                    + "update_time from "
                    + KFKTABLE;

    public long uid;
    public int audit_status;
    public Timestamp create_time;
    public Timestamp update_time;
    public Timestamp audit_time;

    public TableUserAmountRetrialAudit() {}

    public TableUserAmountRetrialAudit(
            long uid,
            int audit_status,
            Timestamp create_time,
            Timestamp update_time,
            Timestamp audit_time) {
        this.uid = uid;
        this.audit_status = audit_status;
        this.create_time = create_time;
        this.update_time = update_time;
        this.audit_time = audit_time;
    }

    public long getUid() {
        return uid;
    }

    public int getAudit_status() {
        return audit_status;
    }

    public Timestamp getCreate_time() {
        return create_time;
    }

    public Timestamp getUpdate_time() {
        return update_time;
    }

    public Timestamp getAudit_time() {
        return audit_time;
    }
}
